#!/usr/bin/env python3
# -*- coding:utf-8 -*-
"""
@author:shengwei
@file:Coroutine_py.py
@time:2018/2/28 002814:05
"""


# 用断点很容易看到执行过程
def consumer():
    r = ''
    while True:
        n = yield r
        if not n:
            return
        print('[CONSUMER] Consuming %s...' % n)
        r = '200 OK'


def produce(c):
    # 首先调用c.send(None)启动生成器
    c.send(None)
    n = 0
    while n < 5:
        n = n + 1
        print('[PRODUCER] Producing %s...' % n)
        r = c.send(n)
        # 一旦生产了东西，通过c.send(n)切换到consumer执行
        # consumer通过yield拿到消息，处理，又通过yield把结果传回
        # produce拿到consumer处理的结果，继续生产下一条消息
        print('[PRODUCER] Consumer return: %s' % r)
        # produce决定不生产了，通过c.close()关闭consumer，整个过程结束
    c.close()


c = consumer()
# consumer函数是一个generator，把一个consumer传入produce后
produce(c)
